;/*FB_PKG_DELIM*/

__d("ActorURIConfig",[],(function(a,b,c,d,e,f){a=Object.freeze({PARAMETER_ACTOR:"av",ENCRYPTED_PARAMETER_ACTOR:"eav"});f["default"]=a}),66);
__d("ActorURI",["ActorURIConfig","URI"],(function(a,b,c,d,e,f,g){var h;function a(a,b){return new(h||(h=c("URI")))(a).addQueryData(c("ActorURIConfig").PARAMETER_ACTOR,b)}g.create=a;g.PARAMETER_ACTOR=c("ActorURIConfig").PARAMETER_ACTOR}),98);
__d("ErrorMetadata",["fb-error"],(function(a,b,c,d,e,f,g){"use strict";a=function(a){function b(){return a.apply(this,arguments)||this}babelHelpers.inheritsLoose(b,a);b.addGlobalMetadata=function(b,c,d){a.addGlobalMetadata.call(this,b,c,d)};return b}(c("fb-error").ErrorMetadata);g["default"]=a}),98);
/**
 * License: https://www.facebook.com/legal/license/bBuG3-YeY7O/
 */
__d("stream-helpers",["ManagedError","Promise"],(function(a,b,c,d,e,f){"use strict";var g;function h(a){b("ManagedError").prototype.constructor.apply(this,arguments)}h.prototype=new(b("ManagedError"))();h.prototype.constructor=h;f.AssertionError=h;function i(a,b){if(typeof a!=="boolean"||!a)throw new h(b);return a}f.assert=i;function j(a){return typeof a==="string"||typeof a==="symbol"}f.typeIsObject=function(a){return typeof a==="object"&&a!==null||typeof a==="function"};f.createDataProperty=function(a,b,c){i(f.typeIsObject(a)),Object.defineProperty(a,b,{value:c,writable:!0,enumerable:!0,configurable:!0})};f.createArrayFromList=function(a){return a.slice()};f.ArrayBufferCopy=function(a,b,c,d,e){new Uint8Array(a).set(new Uint8Array(c,d,e),b)};f.CreateIterResultObject=function(a,b){i(typeof b==="boolean");var c={};Object.defineProperty(c,"value",{value:a,enumerable:!0,writable:!0,configurable:!0});Object.defineProperty(c,"done",{value:b,enumerable:!0,writable:!0,configurable:!0});return c};f.IsFiniteNonNegativeNumber=function(a){if(Number.isNaN(a))return!1;if(a===Infinity)return!1;return a<0?!1:!0};function k(a,b,c){if(typeof a!=="function")throw new TypeError("Argument is not a function");return Function.prototype.apply.call(a,b,c)}f.InvokeOrNoop=function(a,b,c){i(a!==void 0);i(j(b));i(Array.isArray(c));b=a[b];return b===void 0?void 0:k(b,a,c)};f.PromiseInvokeOrNoop=function(a,c,d){i(a!==void 0);i(j(c));i(Array.isArray(d));try{return(g||(g=b("Promise"))).resolve(f.InvokeOrNoop(a,c,d))}catch(a){return(g||(g=b("Promise"))).reject(a)}};f.PromiseInvokeOrPerformFallback=function(a,c,d,e,f){i(a!==void 0);i(j(c));i(Array.isArray(d));i(Array.isArray(f));var h;try{h=a[c]}catch(a){return(g||(g=b("Promise"))).reject(a)}if(h===void 0)return e.apply(void 0,f);try{return(g||(g=b("Promise"))).resolve(k(h,a,d))}catch(a){return(g||(g=b("Promise"))).reject(a)}};f.TransferArrayBuffer=function(a){return a.slice()};f.ValidateAndNormalizeHighWaterMark=function(a){a=Number(a);if(Number.isNaN(a)||a<0)throw new RangeError("highWaterMark property of a queuing strategy must be non-negative and non-NaN");return a};f.ValidateAndNormalizeQueuingStrategy=function(a,b){if(a!==void 0&&typeof a!=="function")throw new TypeError("size property of a queuing strategy must be a function");b=f.ValidateAndNormalizeHighWaterMark(b);return{size:a,highWaterMark:b}}}),null);
/**
 * License: https://www.facebook.com/legal/license/bBuG3-YeY7O/
 */
__d("stream-queue-with-sizes",["stream-helpers"],(function(a,b,c,d,e,f){"use strict";var g=b("stream-helpers").assert,h=b("stream-helpers").IsFiniteNonNegativeNumber;f.DequeueValue=function(a){g("_queue"in a&&"_queueTotalSize"in a,"Spec-level failure: DequeueValue should only be used on containers with [[queue]] and [[queueTotalSize]].");g(a._queue.length>0,"Spec-level failure: should never dequeue from an empty queue.");var b=a._queue.shift();a._queueTotalSize-=b.size;a._queueTotalSize<0&&(a._queueTotalSize=0);return b.value};f.EnqueueValueWithSize=function(a,b,c){g("_queue"in a&&"_queueTotalSize"in a,"Spec-level failure: EnqueueValueWithSize should only be used on containers with [[queue]] and [[queueTotalSize]].");c=Number(c);if(!h(c))throw new RangeError("Size must be a finite, non-NaN, non-negative number.");a._queue.push({value:b,size:c});a._queueTotalSize+=c};f.PeekQueueValue=function(a){g("_queue"in a&&"_queueTotalSize"in a,"Spec-level failure: PeekQueueValue should only be used on containers with [[queue]] and [[queueTotalSize]].");g(a._queue.length>0,"Spec-level failure: should never peek at an empty queue.");a=a._queue[0];return a.value};f.ResetQueue=function(a){g("_queue"in a&&"_queueTotalSize"in a,"Spec-level failure: ResetQueue should only be used on containers with [[queue]] and [[queueTotalSize]]."),a._queue=[],a._queueTotalSize=0}}),null);
/**
 * License: https://www.facebook.com/legal/license/5AQLfddX66n/
 */
__d("stream-utils",["stream-helpers"],(function(a,b,c,d,e,f){"use strict";var g=b("stream-helpers").AssertionError;f.rethrowAssertionErrorRejection=function(a){a&&a.constructor===g&&setTimeout(function(){throw a},0)}}),null);
/**
 * License: https://www.facebook.com/legal/license/wg-Fdn5liPr/
 */
__d("WritableStreamPolyfill",["MaybeNativePromise","stream-helpers","stream-queue-with-sizes","stream-utils"],(function(a,b,c,d,e,f){"use strict";var g=(c=b("stream-helpers")).InvokeOrNoop,h=c.PromiseInvokeOrNoop,i=c.ValidateAndNormalizeQueuingStrategy,j=c.typeIsObject,k=c.assert,l=b("stream-utils").rethrowAssertionErrorRejection,m=(d=b("stream-queue-with-sizes")).DequeueValue,n=d.EnqueueValueWithSize,o=d.PeekQueueValue,p=d.ResetQueue,q="[[StartSteps]]",r="[[AbortSteps]]",s="[[ErrorSteps]]";f=function(){function a(a,b){a===void 0&&(a={});b=b===void 0?{}:b;var c=b.size;b=b.highWaterMark;b=b===void 0?1:b;this._state="writable";this._storedError=void 0;this._writer=void 0;this._writableStreamController=void 0;this._writeRequests=[];this._inFlightWriteRequest=void 0;this._closeRequest=void 0;this._inFlightCloseRequest=void 0;this._pendingAbortRequest=void 0;this._backpressure=!1;var d=a.type;if(d!==void 0)throw new RangeError("Invalid type is specified");this._writableStreamController=new ga(this,a,c,b);this._writableStreamController[q]();Object.defineProperty&&Object.defineProperty(this,"locked",{get:this._isLocked.bind(this)})}var c=a.prototype;c._isLocked=function(){if(u(this)===!1)throw T("locked");return v(this)};c.abort=function(a){if(u(this)===!1)return b("MaybeNativePromise").reject(T("abort"));return v(this)===!0?b("MaybeNativePromise").reject(new TypeError("Cannot abort a stream that already has a writer")):w(this,a)};c.getWriter=function(){if(u(this)===!1)throw T("getWriter");return t(this)};return a}();e.exports={AcquireWritableStreamDefaultWriter:t,IsWritableStream:u,IsWritableStreamLocked:v,WritableStream:f,WritableStreamAbort:w,WritableStreamDefaultControllerError:S,WritableStreamDefaultWriterCloseWithErrorPropagation:a,WritableStreamDefaultWriterRelease:M,WritableStreamDefaultWriterWrite:N,WritableStreamCloseQueuedOrInFlight:F};function t(a){return new ca(a)}function u(a){if(!j(a))return!1;return!Object.prototype.hasOwnProperty.call(a,"_writableStreamController")?!1:!0}function v(a){k(u(a)===!0,"IsWritableStreamLocked should only be used on known writable streams");return a._writer===void 0?!1:!0}function w(a,c){var d=a._state;if(d==="closed")return b("MaybeNativePromise").resolve(void 0);if(d==="errored")return b("MaybeNativePromise").reject(a._storedError);var e=new TypeError("Requested to abort");if(a._pendingAbortRequest!==void 0)return b("MaybeNativePromise").reject(e);k(d==="writable"||d==="erroring","state must be writable or erroring");var f=!1;d==="erroring"&&(f=!0,c=void 0);d=new(b("MaybeNativePromise"))(function(b,d){a._pendingAbortRequest={_resolve:b,_reject:d,_reason:c,_wasAlreadyErroring:f}});f===!1&&z(a,e);return d}function x(a){k(v(a)===!0);k(a._state==="writable");var c=new(b("MaybeNativePromise"))(function(b,c){b={_resolve:b,_reject:c};a._writeRequests.push(b)});return c}function y(a,b){var c=a._state;if(c==="writable"){z(a,b);return}k(c==="erroring");A(a)}function z(a,b){k(a._storedError===void 0,"stream._storedError === undefined");k(a._state==="writable","state must be writable");var c=a._writableStreamController;k(c!==void 0,"controller must not be undefined");a._state="erroring";a._storedError=b;var d=a._writer;d!==void 0&&L(d,b);G(a)===!1&&c._started===!0&&A(a)}function A(a){k(a._state==="erroring","stream._state === erroring");k(G(a)===!1,"WritableStreamHasOperationMarkedInFlight(stream) === false");a._state="errored";a._writableStreamController[s]();var b=a._storedError;for(var c of a._writeRequests)c._reject(b);a._writeRequests=[];if(a._pendingAbortRequest===void 0){H(a);return}var d=a._pendingAbortRequest;a._pendingAbortRequest=void 0;if(d._wasAlreadyErroring===!0){d._reject(b);H(a);return}c=a._writableStreamController[r](d._reason);c.then(function(){d._resolve(),H(a)},function(b){d._reject(b),H(a)})}function B(a){k(a._inFlightWriteRequest!==void 0),a._inFlightWriteRequest._resolve(void 0),a._inFlightWriteRequest=void 0}function C(a,b){k(a._inFlightWriteRequest!==void 0),a._inFlightWriteRequest._reject(b),a._inFlightWriteRequest=void 0,k(a._state==="writable"||a._state==="erroring"),y(a,b)}function D(a){k(a._inFlightCloseRequest!==void 0);a._inFlightCloseRequest._resolve(void 0);a._inFlightCloseRequest=void 0;var b=a._state;k(b==="writable"||b==="erroring");b==="erroring"&&(a._storedError=void 0,a._pendingAbortRequest!==void 0&&(a._pendingAbortRequest._resolve(),a._pendingAbortRequest=void 0));a._state="closed";b=a._writer;b!==void 0&&qa(b);k(a._pendingAbortRequest===void 0,"stream._pendingAbortRequest === undefined");k(a._storedError===void 0,"stream._storedError === undefined")}function E(a,b){k(a._inFlightCloseRequest!==void 0),a._inFlightCloseRequest._reject(b),a._inFlightCloseRequest=void 0,k(a._state==="writable"||a._state==="erroring"),a._pendingAbortRequest!==void 0&&(a._pendingAbortRequest._reject(b),a._pendingAbortRequest=void 0),y(a,b)}function F(a){return a._closeRequest===void 0&&a._inFlightCloseRequest===void 0?!1:!0}function G(a){return a._inFlightWriteRequest===void 0&&a._inFlightCloseRequest===void 0?!1:!0}function aa(a){k(a._inFlightCloseRequest===void 0),k(a._closeRequest!==void 0),a._inFlightCloseRequest=a._closeRequest,a._closeRequest=void 0}function ba(a){k(a._inFlightWriteRequest===void 0,"there must be no pending write request"),k(a._writeRequests.length!==0,"writeRequests must not be empty"),a._inFlightWriteRequest=a._writeRequests.shift()}function H(a){k(a._state==="errored",'_stream_.[[state]] is `"errored"`');a._closeRequest!==void 0&&(k(a._inFlightCloseRequest===void 0),a._closeRequest._reject(a._storedError),a._closeRequest=void 0);var b=a._writer;b!==void 0&&(X(b,a._storedError),b._closedPromise["catch"](function(){}))}function I(a,b){k(a._state==="writable");k(F(a)===!1);var c=a._writer;c!==void 0&&b!==a._backpressure&&(b===!0?ta(c):(k(b===!1),$(c)));a._backpressure=b}var ca=function(){function a(a){if(u(a)===!1)throw new TypeError("WritableStreamDefaultWriter can only be constructed with a WritableStream instance");if(v(a)===!0)throw new TypeError("This stream has already been locked for exclusive writing by another writer");this._ownerWritableStream=a;a._writer=this;var b=a._state;if(b==="writable")F(a)===!1&&a._backpressure===!0?ra(this):Z(this),W(this);else if(b==="erroring")Y(this,a._storedError),this._readyPromise["catch"](function(){}),W(this);else if(b==="closed")Z(this),oa(this);else{k(b==="errored","state must be errored");b=a._storedError;Y(this,b);this._readyPromise["catch"](function(){});na(this,b);this._closedPromise["catch"](function(){})}Object.defineProperty&&(Object.defineProperty(this,"closed",{get:this._isClosed.bind(this)}),Object.defineProperty(this,"desiredSize",{get:this._getDesiredSize.bind(this)}),Object.defineProperty(this,"ready",{get:this._isReady.bind(this)}))}var c=a.prototype;c._isClosed=function(){return J(this)===!1?b("MaybeNativePromise").reject(U("closed")):this._closedPromise};c._getDesiredSize=function(){if(J(this)===!1)throw U("desiredSize");if(this._ownerWritableStream===void 0)throw V("desiredSize");return fa(this)};c._isReady=function(){return J(this)===!1?b("MaybeNativePromise").reject(U("ready")):this._readyPromise};c.abort=function(a){if(J(this)===!1)return b("MaybeNativePromise").reject(U("abort"));return this._ownerWritableStream===void 0?b("MaybeNativePromise").reject(V("abort")):da(this,a)};c.close=function(){if(J(this)===!1)return b("MaybeNativePromise").reject(U("close"));var a=this._ownerWritableStream;if(a===void 0)return b("MaybeNativePromise").reject(V("close"));return F(a)===!0?b("MaybeNativePromise").reject(new TypeError("cannot close an already-closing stream")):K(this)};c.releaseLock=function(){if(J(this)===!1)throw U("releaseLock");var a=this._ownerWritableStream;if(a===void 0)return;k(a._writer!==void 0);M(this)};c.write=function(a){if(J(this)===!1)return b("MaybeNativePromise").reject(U("write"));return this._ownerWritableStream===void 0?b("MaybeNativePromise").reject(V("write to")):N(this,a)};return a}();function J(a){if(!j(a))return!1;return!Object.prototype.hasOwnProperty.call(a,"_ownerWritableStream")?!1:!0}function da(a,b){a=a._ownerWritableStream;k(a!==void 0);return w(a,b)}function K(a){var c=a._ownerWritableStream;k(c!==void 0);var d=c._state;if(d==="closed"||d==="errored")return b("MaybeNativePromise").reject(new TypeError("The stream (in "+d+" state) is not in the writable state and cannot be closed"));k(d==="writable"||d==="erroring");k(F(c)===!1);var e=new(b("MaybeNativePromise"))(function(a,b){a={_resolve:a,_reject:b};c._closeRequest=a});c._backpressure===!0&&d==="writable"&&$(a);ha(c._writableStreamController);return e}function a(a){var c=a._ownerWritableStream;k(c!==void 0);var d=c._state;if(F(c)===!0||d==="closed")return b("MaybeNativePromise").resolve();if(d==="errored")return b("MaybeNativePromise").reject(c._storedError);k(d==="writable"||d==="erroring");return K(a)}function ea(a,b){a._closedPromiseState==="pending"?X(a,b):pa(a,b),a._closedPromise["catch"](function(){})}function L(a,b){a._readyPromiseState==="pending"?sa(a,b):ua(a,b),a._readyPromise["catch"](function(){})}function fa(a){a=a._ownerWritableStream;var b=a._state;if(b==="errored"||b==="erroring")return null;return b==="closed"?0:O(a._writableStreamController)}function M(a){var b=a._ownerWritableStream;k(b!==void 0);k(b._writer===a);var c=new TypeError("Writer was released and can no longer be used to monitor the stream's closedness");L(a,c);ea(a,c);b._writer=void 0;a._ownerWritableStream=void 0}function N(a,c){var d=a._ownerWritableStream;k(d!==void 0);var e=d._writableStreamController,f=ia(e,c);if(d!==a._ownerWritableStream)return b("MaybeNativePromise").reject(V("write to"));a=d._state;if(a==="errored")return b("MaybeNativePromise").reject(d._storedError);if(F(d)===!0||a==="closed")return b("MaybeNativePromise").reject(new TypeError("The stream is closing or closed and cannot be written to"));if(a==="erroring")return b("MaybeNativePromise").reject(d._storedError);k(a==="writable");a=x(d);ja(e,c,f);return a}var ga=function(){function a(a,b,c,d){if(u(a)===!1)throw new TypeError("WritableStreamDefaultController can only be constructed with a WritableStream instance");if(a._writableStreamController!==void 0)throw new TypeError("WritableStreamDefaultController instances can only be created by the WritableStream constructor");this._controlledWritableStream=a;this._underlyingSink=b;this._queue=void 0;this._queueTotalSize=void 0;p(this);this._started=!1;b=i(c,d);this._strategySize=b.size;this._strategyHWM=b.highWaterMark;c=R(this);I(a,c)}var c=a.prototype;c.error=function(a){if(ka(this)===!1)throw new TypeError("WritableStreamDefaultController.prototype.error can only be used on a WritableStreamDefaultController");var b=this._controlledWritableStream._state;if(b!=="writable")return;S(this,a)};c[r]=function(a){return h(this._underlyingSink,"abort",[a])};c[s]=function(){p(this)};c[q]=function(){var a=this,c=g(this._underlyingSink,"start",[this]),d=this._controlledWritableStream;b("MaybeNativePromise").resolve(c).then(function(){k(d._state==="writable"||d._state==="erroring"),a._started=!0,P(a)},function(b){k(d._state==="writable"||d._state==="erroring"),a._started=!0,y(d,b)})["catch"](l)};return a}();function ha(a){n(a,"close",0),P(a)}function ia(a,b){var c=a._strategySize;if(c===void 0)return 1;try{return c(b)}catch(b){Q(a,b);return 1}}function O(a){return a._strategyHWM-a._queueTotalSize}function ja(a,b,c){b={chunk:b};try{n(a,b,c)}catch(b){Q(a,b);return}b=a._controlledWritableStream;if(F(b)===!1&&b._state==="writable"){c=R(a);I(b,c)}P(a)}function ka(a){if(!j(a))return!1;return!Object.prototype.hasOwnProperty.call(a,"_underlyingSink")?!1:!0}function P(a){var b=a._controlledWritableStream;if(a._started===!1)return;if(b._inFlightWriteRequest!==void 0)return;var c=b._state;if(c==="closed"||c==="errored")return;if(c==="erroring"){A(b);return}if(a._queue.length===0)return;c=o(a);c==="close"?la(a):ma(a,c.chunk)}function Q(a,b){a._controlledWritableStream._state==="writable"&&S(a,b)}function la(a){var b=a._controlledWritableStream;aa(b);m(a);k(a._queue.length===0,"queue must be empty once the final write record is dequeued");a=h(a._underlyingSink,"close",[]);a.then(function(){D(b)},function(a){E(b,a)})["catch"](l)}function ma(a,b){var c=a._controlledWritableStream;ba(c);b=h(a._underlyingSink,"write",[b,a]);b.then(function(){B(c);var b=c._state;k(b==="writable"||b==="erroring");m(a);if(F(c)===!1&&b==="writable"){b=R(a);I(c,b)}P(a)},function(a){C(c,a)})["catch"](l)}function R(a){a=O(a);return a<=0}function S(a,b){a=a._controlledWritableStream;k(a._state==="writable");z(a,b)}function T(a){return new TypeError("WritableStream.prototype."+a+" can only be used on a WritableStream")}function U(a){return new TypeError("WritableStreamDefaultWriter.prototype."+a+" can only be used on a WritableStreamDefaultWriter")}function V(a){return new TypeError("Cannot "+a+" a stream using a released writer")}function W(a){a._closedPromise=new(b("MaybeNativePromise"))(function(b,c){a._closedPromise_resolve=b,a._closedPromise_reject=c,a._closedPromiseState="pending"})}function na(a,c){a._closedPromise=b("MaybeNativePromise").reject(c),a._closedPromise_resolve=void 0,a._closedPromise_reject=void 0,a._closedPromiseState="rejected"}function oa(a){a._closedPromise=b("MaybeNativePromise").resolve(void 0),a._closedPromise_resolve=void 0,a._closedPromise_reject=void 0,a._closedPromiseState="resolved"}function X(a,b){k(a._closedPromise_resolve!==void 0,"writer._closedPromise_resolve !== undefined"),k(a._closedPromise_reject!==void 0,"writer._closedPromise_reject !== undefined"),k(a._closedPromiseState==="pending","writer._closedPromiseState is pending"),a._closedPromise_reject(b),a._closedPromise_resolve=void 0,a._closedPromise_reject=void 0,a._closedPromiseState="rejected"}function pa(a,c){k(a._closedPromise_resolve===void 0,"writer._closedPromise_resolve === undefined"),k(a._closedPromise_reject===void 0,"writer._closedPromise_reject === undefined"),k(a._closedPromiseState!=="pending","writer._closedPromiseState is not pending"),a._closedPromise=b("MaybeNativePromise").reject(c),a._closedPromiseState="rejected"}function qa(a){k(a._closedPromise_resolve!==void 0,"writer._closedPromise_resolve !== undefined"),k(a._closedPromise_reject!==void 0,"writer._closedPromise_reject !== undefined"),k(a._closedPromiseState==="pending","writer._closedPromiseState is pending"),a._closedPromise_resolve(void 0),a._closedPromise_resolve=void 0,a._closedPromise_reject=void 0,a._closedPromiseState="resolved"}function ra(a){a._readyPromise=new(b("MaybeNativePromise"))(function(b,c){a._readyPromise_resolve=b,a._readyPromise_reject=c}),a._readyPromiseState="pending"}function Y(a,c){a._readyPromise=b("MaybeNativePromise").reject(c),a._readyPromise_resolve=void 0,a._readyPromise_reject=void 0,a._readyPromiseState="rejected"}function Z(a){a._readyPromise=b("MaybeNativePromise").resolve(void 0),a._readyPromise_resolve=void 0,a._readyPromise_reject=void 0,a._readyPromiseState="fulfilled"}function sa(a,b){k(a._readyPromise_resolve!==void 0,"writer._readyPromise_resolve !== undefined"),k(a._readyPromise_reject!==void 0,"writer._readyPromise_reject !== undefined"),a._readyPromise_reject(b),a._readyPromise_resolve=void 0,a._readyPromise_reject=void 0,a._readyPromiseState="rejected"}function ta(a){k(a._readyPromise_resolve===void 0,"writer._readyPromise_resolve === undefined"),k(a._readyPromise_reject===void 0,"writer._readyPromise_reject === undefined"),a._readyPromise=new(b("MaybeNativePromise"))(function(b,c){a._readyPromise_resolve=b,a._readyPromise_reject=c}),a._readyPromiseState="pending"}function ua(a,c){k(a._readyPromise_resolve===void 0,"writer._readyPromise_resolve === undefined"),k(a._readyPromise_reject===void 0,"writer._readyPromise_reject === undefined"),a._readyPromise=b("MaybeNativePromise").reject(c),a._readyPromiseState="rejected"}function $(a){k(a._readyPromise_resolve!==void 0,"writer._readyPromise_resolve !== undefined"),k(a._readyPromise_reject!==void 0,"writer._readyPromise_reject !== undefined"),a._readyPromise_resolve(void 0),a._readyPromise_resolve=void 0,a._readyPromise_reject=void 0,a._readyPromiseState="fulfilled"}}),null);
/**
 * License: https://www.facebook.com/legal/license/wg-Fdn5liPr/
 */
__d("ReadableStreamPolyfill",["MaybeNativePromise","WritableStreamPolyfill","stream-helpers","stream-queue-with-sizes","stream-utils"],(function(a,b,c,d,e,f){"use strict";var g=(c=b("stream-helpers")).ArrayBufferCopy,h=c.CreateIterResultObject,i=c.IsFiniteNonNegativeNumber,j=c.InvokeOrNoop,k=c.PromiseInvokeOrNoop,l=c.TransferArrayBuffer,m=c.ValidateAndNormalizeQueuingStrategy,n=c.ValidateAndNormalizeHighWaterMark,o=c.createArrayFromList,p=c.createDataProperty,q=c.typeIsObject,r=c.assert,s=b("stream-utils").rethrowAssertionErrorRejection,t=b("stream-queue-with-sizes").DequeueValue,u=b("stream-queue-with-sizes").EnqueueValueWithSize,v=b("stream-queue-with-sizes").ResetQueue,aa=(d=b("WritableStreamPolyfill")).AcquireWritableStreamDefaultWriter,ba=d.IsWritableStream,ca=d.IsWritableStreamLocked,da=d.WritableStreamAbort,ea=d.WritableStreamDefaultWriterCloseWithErrorPropagation,fa=d.WritableStreamDefaultWriterRelease,ga=d.WritableStreamDefaultWriterWrite,w=d.WritableStreamCloseQueuedOrInFlight,x="[[CancelSteps]]",y="[[PullSteps]]",z=function(){function a(a,b){a===void 0&&(a={});b=b===void 0?{}:b;var c=b.size;b=b.highWaterMark;this._state="readable";this._reader=void 0;this._storedError=void 0;this._disturbed=!1;this._readableStreamController=void 0;var d=a.type,e=String(d);if(e==="bytes")b===void 0&&(b=0),this._readableStreamController=new Ca(this,a,b);else if(d===void 0)b===void 0&&(b=1),this._readableStreamController=new ya(this,a,c,b);else throw new RangeError("Invalid type is specified");Object.defineProperty&&Object.defineProperty(this,"locked",{get:this._isLocked.bind(this)})}var c=a.prototype;c._isLocked=function(){if(B(this)===!1)throw V("locked");return C(this)};c.cancel=function(a){if(B(this)===!1)return b("MaybeNativePromise").reject(V("cancel"));return C(this)===!0?b("MaybeNativePromise").reject(new TypeError("Cannot cancel a stream that already has a reader")):D(this,a)};c.getReader=function(a){a=a===void 0?{}:a;a=a.mode;if(B(this)===!1)throw V("getReader");if(a===void 0)return A(this);a=String(a);if(a==="byob")return ha(this);throw new RangeError("Invalid mode is specified")};c.pipeThrough=function(a,b){var c=a.writable;a=a.readable;if(c===void 0||a===void 0)throw new TypeError("readable and writable arguments must be defined");c=this.pipeTo(c,b);db(c);return a};c.pipeTo=function(a,c){var d=this;c=c===void 0?{}:c;var e=c.preventClose,f=c.preventAbort,g=c.preventCancel;if(B(this)===!1)return b("MaybeNativePromise").reject(V("pipeTo"));if(ba(a)===!1)return b("MaybeNativePromise").reject(new TypeError("ReadableStream.prototype.pipeTo's first argument must be a WritableStream"));e=Boolean(e);f=Boolean(f);g=Boolean(g);if(C(this)===!0)return b("MaybeNativePromise").reject(new TypeError("ReadableStream.prototype.pipeTo cannot be used on a locked ReadableStream"));if(ca(a)===!0)return b("MaybeNativePromise").reject(new TypeError("ReadableStream.prototype.pipeTo cannot be used on a locked WritableStream"));var h=A(this),i=aa(a),j=!1,k=b("MaybeNativePromise").resolve();return new(b("MaybeNativePromise"))(function(c,l){function m(){k=b("MaybeNativePromise").resolve();return j===!0?b("MaybeNativePromise").resolve():i._readyPromise.then(function(){return xa(h).then(function(a){var b=a.value;a=a.done;if(a===!0)return;k=ga(i,b)["catch"](function(){})})}).then(m)}p(d,h._closedPromise,function(b){f===!1?r(function(){return da(a,b)},!0,b):t(!0,b)});p(a,i._closedPromise,function(a){g===!1?r(function(){return D(d,a)},!0,a):t(!0,a)});q(d,h._closedPromise,function(){e===!1?r(function(){return ea(i)}):t()});if(w(a)===!0||a._state==="closed"){var n=new TypeError("the destination writable stream closed before all data could be piped to it");g===!1?r(function(){return D(d,n)},!0,n):t(!0,n)}m()["catch"](function(a){k=b("MaybeNativePromise").resolve(),s(a)});function o(){var a=k;return k.then(function(){return a!==k?o():void 0})}function p(a,b,c){a._state==="errored"?c(a._storedError):b["catch"](c)["catch"](s)}function q(a,b,c){a._state==="closed"?c():b.then(c)["catch"](s)}function r(b,c,d){if(j===!0)return;j=!0;a._state==="writable"&&w(a)===!1?o().then(e):e();function e(){b().then(function(){return u(c,d)},function(a){return u(!0,a)})["catch"](s)}}function t(b,c){if(j===!0)return;j=!0;a._state==="writable"&&w(a)===!1?o().then(function(){return u(b,c)})["catch"](s):u(b,c)}function u(a,b){fa(i),va(h),a?l(b):c(void 0)}})};c.tee=function(){if(B(this)===!1)throw V("tee");var a=ia(this,!1);return o(a)};return a}();e.exports={ReadableStream:z,IsReadableStreamDisturbed:a,ReadableStreamDefaultControllerClose:N,ReadableStreamDefaultControllerEnqueue:O,ReadableStreamDefaultControllerError:P,ReadableStreamDefaultControllerGetDesiredSize:Aa};function ha(a){return new sa(a)}function A(a){return new ra(a)}function B(a){if(!q(a))return!1;return!Object.prototype.hasOwnProperty.call(a,"_readableStreamController")?!1:!0}function a(a){r(B(a)===!0,"IsReadableStreamDisturbed should only be used on known readable streams");return a._disturbed}function C(a){r(B(a)===!0,"IsReadableStreamLocked should only be used on known readable streams");return a._reader===void 0?!1:!0}function ia(a,c){r(B(a)===!0);r(typeof c==="boolean");var d=A(a),e={closedOrErrored:!1,canceled1:!1,canceled2:!1,reason1:void 0,reason2:void 0};e.promise=new(b("MaybeNativePromise"))(function(a){e._resolve=a});var f=ja();f._reader=d;f._teeState=e;f._cloneForBranch2=c;c=ka();c._stream=a;c._teeState=e;var g=la();g._stream=a;g._teeState=e;a=Object.create(Object.prototype);p(a,"pull",f);p(a,"cancel",c);c=new z(a);a=Object.create(Object.prototype);p(a,"pull",f);p(a,"cancel",g);g=new z(a);f._branch1=c._readableStreamController;f._branch2=g._readableStreamController;d._closedPromise["catch"](function(a){if(e.closedOrErrored===!0)return;P(f._branch1,a);P(f._branch2,a);e.closedOrErrored=!0});return[c,g]}function ja(){function a(){var b=a._reader,c=a._branch1,d=a._branch2,e=a._teeState;return xa(b).then(function(a){r(q(a));var b=a.value;a=a.done;r(typeof a==="boolean");a===!0&&e.closedOrErrored===!1&&(e.canceled1===!1&&N(c),e.canceled2===!1&&N(d),e.closedOrErrored=!0);if(e.closedOrErrored===!0)return;a=b;b=b;e.canceled1===!1&&O(c,a);e.canceled2===!1&&O(d,b)})}return a}function ka(){function a(b){var c=a._stream,d=a._teeState;d.canceled1=!0;d.reason1=b;if(d.canceled2===!0){b=o([d.reason1,d.reason2]);c=D(c,b);d._resolve(c)}return d.promise}return a}function la(){function a(b){var c=a._stream,d=a._teeState;d.canceled2=!0;d.reason2=b;if(d.canceled1===!0){b=o([d.reason1,d.reason2]);c=D(c,b);d._resolve(c)}return d.promise}return a}function ma(a){r(J(a._reader)===!0);r(a._state==="readable"||a._state==="closed");var c=new(b("MaybeNativePromise"))(function(b,c){b={_resolve:b,_reject:c};a._reader._readIntoRequests.push(b)});return c}function na(a){r(K(a._reader)===!0);r(a._state==="readable");var c=new(b("MaybeNativePromise"))(function(b,c){b={_resolve:b,_reject:c};a._reader._readRequests.push(b)});return c}function D(a,c){a._disturbed=!0;if(a._state==="closed")return b("MaybeNativePromise").resolve(void 0);if(a._state==="errored")return b("MaybeNativePromise").reject(a._storedError);E(a);a=a._readableStreamController[x](c);return a.then(function(){return void 0})}function E(a){r(a._state==="readable");a._state="closed";a=a._reader;if(a===void 0)return void 0;if(K(a)===!0){for(var b of a._readRequests){var c=b._resolve;c(h(void 0,!0))}a._readRequests=[]}bb(a);return void 0}function oa(a,b){r(B(a)===!0,"stream must be ReadableStream");r(a._state==="readable","state must be readable");a._state="errored";a._storedError=b;a=a._reader;if(a===void 0)return void 0;if(K(a)===!0){for(var c of a._readRequests)c._reject(b);a._readRequests=[]}else{r(J(a),"reader must be ReadableStreamBYOBReader");for(c of a._readIntoRequests)c._reject(b);a._readIntoRequests=[]}$a(a,b);a._closedPromise["catch"](function(){})}function pa(a,b,c){a=a._reader;r(a._readIntoRequests.length>0);a=a._readIntoRequests.shift();a._resolve(h(b,c))}function F(a,b,c){a=a._reader;r(a._readRequests.length>0);a=a._readRequests.shift();a._resolve(h(b,c))}function qa(a){return a._reader._readIntoRequests.length}function G(a){return a._reader._readRequests.length}function H(a){a=a._reader;if(a===void 0)return!1;return J(a)===!1?!1:!0}function I(a){a=a._reader;if(a===void 0)return!1;return K(a)===!1?!1:!0}var ra=function(){function a(a){if(B(a)===!1)throw new TypeError("ReadableStreamDefaultReader can only be constructed with a ReadableStream instance");if(C(a)===!0)throw new TypeError("This stream has already been locked for exclusive reading by another reader");ta(this,a);this._readRequests=[];Object.defineProperty&&Object.defineProperty(this,"closed",{get:this._isClosed.bind(this)})}var c=a.prototype;c._isClosed=function(){return K(this)===!1?b("MaybeNativePromise").reject(X("closed")):this._closedPromise};c.cancel=function(a){if(K(this)===!1)return b("MaybeNativePromise").reject(X("cancel"));return this._ownerReadableStream===void 0?b("MaybeNativePromise").reject(W("cancel")):ua(this,a)};c.read=function(){if(K(this)===!1)return b("MaybeNativePromise").reject(X("read"));return this._ownerReadableStream===void 0?b("MaybeNativePromise").reject(W("read from")):xa(this)};c.releaseLock=function(){if(K(this)===!1)throw X("releaseLock");if(this._ownerReadableStream===void 0)return;if(this._readRequests.length>0)throw new TypeError("Tried to release a reader lock when that reader has pending read() calls un-settled");va(this)};return a}(),sa=function(){function a(a){if(!B(a))throw new TypeError("ReadableStreamBYOBReader can only be constructed with a ReadableStream instance given a byte source");if(R(a._readableStreamController)===!1)throw new TypeError("Cannot construct a ReadableStreamBYOBReader for a stream not constructed with a byte source");if(C(a))throw new TypeError("This stream has already been locked for exclusive reading by another reader");ta(this,a);this._readIntoRequests=[];Object.defineProperty&&Object.defineProperty(this,"closed",{get:this._isClosed.bind(this)})}var c=a.prototype;c._isClosed=function(){return!J(this)?b("MaybeNativePromise").reject(Y("closed")):this._closedPromise};c.cancel=function(a){if(!J(this))return b("MaybeNativePromise").reject(Y("cancel"));return this._ownerReadableStream===void 0?b("MaybeNativePromise").reject(W("cancel")):ua(this,a)};c.read=function(a){if(!J(this))return b("MaybeNativePromise").reject(Y("read"));if(this._ownerReadableStream===void 0)return b("MaybeNativePromise").reject(W("read from"));if(!ArrayBuffer.isView(a))return b("MaybeNativePromise").reject(new TypeError("view must be an array buffer view"));return a.byteLength===0?b("MaybeNativePromise").reject(new TypeError("view must have non-zero byteLength")):wa(this,a)};c.releaseLock=function(){if(!J(this))throw Y("releaseLock");if(this._ownerReadableStream===void 0)return;if(this._readIntoRequests.length>0)throw new TypeError("Tried to release a reader lock when that reader has pending read() calls un-settled");va(this)};return a}();function J(a){if(!q(a))return!1;return!Object.prototype.hasOwnProperty.call(a,"_readIntoRequests")?!1:!0}function K(a){if(!q(a))return!1;return!Object.prototype.hasOwnProperty.call(a,"_readRequests")?!1:!0}function ta(a,b){a._ownerReadableStream=b,b._reader=a,b._state==="readable"?Xa(a):b._state==="closed"?Za(a):(r(b._state==="errored","state must be errored"),Ya(a,b._storedError),a._closedPromise["catch"](function(){}))}function ua(a,b){a=a._ownerReadableStream;r(a!==void 0);return D(a,b)}function va(a){r(a._ownerReadableStream!==void 0),r(a._ownerReadableStream._reader===a),a._ownerReadableStream._state==="readable"?$a(a,new TypeError("Reader was released and can no longer be used to monitor the stream's closedness")):ab(a,new TypeError("Reader was released and can no longer be used to monitor the stream's closedness")),a._closedPromise["catch"](function(){}),a._ownerReadableStream._reader=void 0,a._ownerReadableStream=void 0}function wa(a,c){a=a._ownerReadableStream;r(a!==void 0);a._disturbed=!0;return a._state==="errored"?b("MaybeNativePromise").reject(a._storedError):Ma(a._readableStreamController,c)}function xa(a){a=a._ownerReadableStream;r(a!==void 0);a._disturbed=!0;if(a._state==="closed")return b("MaybeNativePromise").resolve(h(void 0,!0));if(a._state==="errored")return b("MaybeNativePromise").reject(a._storedError);r(a._state==="readable");return a._readableStreamController[y]()}var ya=function(){function a(a,c,d,e){if(B(a)===!1)throw new TypeError("ReadableStreamDefaultController can only be constructed with a ReadableStream instance");if(a._readableStreamController!==void 0)throw new TypeError("ReadableStreamDefaultController instances can only be created by the ReadableStream constructor");this._controlledReadableStream=a;this._underlyingSource=c;this._queue=void 0;this._queueTotalSize=void 0;v(this);this._started=!1;this._closeRequested=!1;this._pullAgain=!1;this._pulling=!1;a=m(d,e);this._strategySize=a.size;this._strategyHWM=a.highWaterMark;var f=this;d=j(c,"start",[this]);b("MaybeNativePromise").resolve(d).then(function(){f._started=!0,r(f._pulling===!1),r(f._pullAgain===!1),M(f)},function(a){Q(f,a)})["catch"](s);Object.defineProperty&&Object.defineProperty(this,"desiredSize",{get:this._getDesiredSize.bind(this)})}var c=a.prototype;c._getDesiredSize=function(){if(L(this)===!1)throw Z("desiredSize");return Aa(this)};c.close=function(){if(L(this)===!1)throw Z("close");if(this._closeRequested===!0)throw new TypeError("The stream has already been closed; do not close it again!");var a=this._controlledReadableStream._state;if(a!=="readable")throw new TypeError("The stream (in "+a+" state) is not in the readable state and cannot be closed");N(this)};c.enqueue=function(a){if(L(this)===!1)throw Z("enqueue");if(this._closeRequested===!0)throw new TypeError("stream is closed or draining");var b=this._controlledReadableStream._state;if(b!=="readable")throw new TypeError("The stream (in "+b+" state) is not in the readable state and cannot be enqueued to");return O(this,a)};c.error=function(a){if(L(this)===!1)throw Z("error");var b=this._controlledReadableStream;if(b._state!=="readable")throw new TypeError("The stream is "+b._state+" and so cannot be errored");P(this,a)};c[x]=function(a){v(this);return k(this._underlyingSource,"cancel",[a])};c[y]=function(){var a=this._controlledReadableStream;if(this._queue.length>0){var c=t(this);this._closeRequested===!0&&this._queue.length===0?E(a):M(this);return b("MaybeNativePromise").resolve(h(c,!1))}c=na(a);M(this);return c};return a}();function L(a){if(!q(a))return!1;return!Object.prototype.hasOwnProperty.call(a,"_underlyingSource")?!1:!0}function M(a){var b=za(a);if(b===!1)return void 0;if(a._pulling===!0){a._pullAgain=!0;return void 0}r(a._pullAgain===!1);a._pulling=!0;b=k(a._underlyingSource,"pull",[a]);b.then(function(){a._pulling=!1;if(a._pullAgain===!0){a._pullAgain=!1;return M(a)}return void 0},function(b){Q(a,b)})["catch"](s);return void 0}function za(a){var b=a._controlledReadableStream;if(b._state==="closed"||b._state==="errored")return!1;if(a._closeRequested===!0)return!1;if(a._started===!1)return!1;if(C(b)===!0&&G(b)>0)return!0;b=Aa(a);return b>0?!0:!1}function N(a){var b=a._controlledReadableStream;r(a._closeRequested===!1);r(b._state==="readable");a._closeRequested=!0;a._queue.length===0&&E(b)}function O(a,b){var c=a._controlledReadableStream;r(a._closeRequested===!1);r(c._state==="readable");if(C(c)===!0&&G(c)>0)F(c,b,!1);else{c=1;if(a._strategySize!==void 0){var d=a._strategySize;try{c=d(b)}catch(b){Q(a,b);throw b}}try{u(a,b,c)}catch(b){Q(a,b);throw b}}M(a);return void 0}function P(a,b){var c=a._controlledReadableStream;r(c._state==="readable");v(a);oa(c,b)}function Q(a,b){a._controlledReadableStream._state==="readable"&&P(a,b)}function Aa(a){var b=a._controlledReadableStream;b=b._state;if(b==="errored")return null;return b==="closed"?0:a._strategyHWM-a._queueTotalSize}var Ba=function(){function a(a,b){this._associatedReadableByteStreamController=a,this._view=b,Object.defineProperty&&Object.defineProperty(this,"view",{get:this._getView.bind(this)})}var b=a.prototype;b._getView=function(){return this._view};b.respond=function(a){if(Da(this)===!1)throw cb("respond");if(this._associatedReadableByteStreamController===void 0)throw new TypeError("This BYOB request has been invalidated");Va(this._associatedReadableByteStreamController,a)};b.respondWithNewView=function(a){if(Da(this)===!1)throw cb("respond");if(this._associatedReadableByteStreamController===void 0)throw new TypeError("This BYOB request has been invalidated");if(!ArrayBuffer.isView(a))throw new TypeError("You can only respond with array buffer views");Wa(this._associatedReadableByteStreamController,a)};return a}(),Ca=function(){function a(a,c,d){if(B(a)===!1)throw new TypeError("ReadableByteStreamController can only be constructed with a ReadableStream instance given a byte source");if(a._readableStreamController!==void 0)throw new TypeError("ReadableByteStreamController instances can only be created by the ReadableStream constructor given a byte source");this._controlledReadableStream=a;this._underlyingByteSource=c;this._pullAgain=!1;this._pulling=!1;Ea(this);this._queue=this._queueTotalSize=void 0;v(this);this._closeRequested=!1;this._started=!1;this._strategyHWM=n(d);d=c.autoAllocateChunkSize;if(d!==void 0&&(Number.isInteger(d)===!1||d<=0))throw new RangeError("autoAllocateChunkSize must be a positive integer");this._autoAllocateChunkSize=d;this._pendingPullIntos=[];var e=this;d=j(c,"start",[this]);b("MaybeNativePromise").resolve(d).then(function(){e._started=!0,r(e._pulling===!1),r(e._pullAgain===!1),S(e)},function(b){a._state==="readable"&&U(e,b)})["catch"](s);Object.defineProperty&&(Object.defineProperty(this,"byobRequest",{get:this._getByobRequest.bind(this)}),Object.defineProperty(this,"desiredSize",{get:this._getByobRequest.bind(this)}))}var c=a.prototype;c._getByobRequest=function(){if(R(this)===!1)throw $("byobRequest");if(this._byobRequest===void 0&&this._pendingPullIntos.length>0){var a=this._pendingPullIntos[0];a=new Uint8Array(a.buffer,a.byteOffset+a.bytesFilled,a.byteLength-a.bytesFilled);this._byobRequest=new Ba(this,a)}return this._byobRequest};c._getDesiredSize=function(){if(R(this)===!1)throw $("desiredSize");return Ua(this)};c.close=function(){if(R(this)===!1)throw $("close");if(this._closeRequested===!0)throw new TypeError("The stream has already been closed; do not close it again!");var a=this._controlledReadableStream._state;if(a!=="readable")throw new TypeError("The stream (in "+a+" state) is not in the readable state and cannot be closed");Sa(this)};c.enqueue=function(a){if(R(this)===!1)throw $("enqueue");if(this._closeRequested===!0)throw new TypeError("stream is closed or draining");var b=this._controlledReadableStream._state;if(b!=="readable")throw new TypeError("The stream (in "+b+" state) is not in the readable state and cannot be enqueued to");if(!ArrayBuffer.isView(a))throw new TypeError("You can only enqueue array buffer views when using a ReadableByteStreamController");Ta(this,a)};c.error=function(a){if(R(this)===!1)throw $("error");var b=this._controlledReadableStream;if(b._state!=="readable")throw new TypeError("The stream is "+b._state+" and so cannot be errored");U(this,a)};c[x]=function(a){if(this._pendingPullIntos.length>0){var b=this._pendingPullIntos[0];b.bytesFilled=0}v(this);return k(this._underlyingByteSource,"cancel",[a])};c[y]=function(){var a=this._controlledReadableStream;r(I(a)===!0);if(this._queueTotalSize>0){r(G(a)===0);var c=this._queue.shift();this._queueTotalSize-=c.byteLength;Ja(this);var d;try{d=new Uint8Array(c.buffer,c.byteOffset,c.byteLength)}catch(a){return b("MaybeNativePromise").reject(a)}return b("MaybeNativePromise").resolve(h(d,!1))}c=this._autoAllocateChunkSize;if(c!==void 0){var e;try{e=new ArrayBuffer(c)}catch(a){return b("MaybeNativePromise").reject(a)}c={buffer:e,byteOffset:0,byteLength:c,bytesFilled:0,elementSize:1,ctor:Uint8Array,readerType:"default"};this._pendingPullIntos.push(c)}c=na(a);S(this);return c};return a}();function R(a){if(!q(a))return!1;return!Object.prototype.hasOwnProperty.call(a,"_underlyingByteSource")?!1:!0}function Da(a){if(!q(a))return!1;return!Object.prototype.hasOwnProperty.call(a,"_associatedReadableByteStreamController")?!1:!0}function S(a){var b=Ra(a);if(b===!1)return void 0;if(a._pulling===!0){a._pullAgain=!0;return void 0}r(a._pullAgain===!1);a._pulling=!0;b=k(a._underlyingByteSource,"pull",[a]);b.then(function(){a._pulling=!1,a._pullAgain===!0&&(a._pullAgain=!1,S(a))},function(b){a._controlledReadableStream._state==="readable"&&U(a,b)})["catch"](s);return void 0}function Ea(a){Ka(a),a._pendingPullIntos=[]}function Fa(a,b){r(a._state!=="errored","state must not be errored");var c=!1;a._state==="closed"&&(r(b.bytesFilled===0),c=!0);var d=Ga(b);b.readerType==="default"?F(a,d,c):(r(b.readerType==="byob"),pa(a,d,c))}function Ga(a){var b=a.bytesFilled,c=a.elementSize;r(b<=a.byteLength);r(b%c===0);return new a.ctor(a.buffer,a.byteOffset,b/c)}function T(a,b,c,d){a._queue.push({buffer:b,byteOffset:c,byteLength:d}),a._queueTotalSize+=d}function Ha(a,b){var c=b.elementSize,d=b.bytesFilled-b.bytesFilled%c,e=Math.min(a._queueTotalSize,b.byteLength-b.bytesFilled),f=b.bytesFilled+e;f=f-f%c;c=e;e=!1;f>d&&(c=f-b.bytesFilled,e=!0);d=a._queue;while(c>0){f=d[0];var h=Math.min(c,f.byteLength),i=b.byteOffset+b.bytesFilled;g(b.buffer,i,f.buffer,f.byteOffset,h);f.byteLength===h?d.shift():(f.byteOffset+=h,f.byteLength-=h);a._queueTotalSize-=h;Ia(a,h,b);c-=h}e===!1&&(r(a._queueTotalSize===0,"queue must be empty"),r(b.bytesFilled>0),r(b.bytesFilled<b.elementSize));return e}function Ia(a,b,c){r(a._pendingPullIntos.length===0||a._pendingPullIntos[0]===c),Ka(a),c.bytesFilled+=b}function Ja(a){r(a._controlledReadableStream._state==="readable"),a._queueTotalSize===0&&a._closeRequested===!0?E(a._controlledReadableStream):S(a)}function Ka(a){if(a._byobRequest===void 0)return;a._byobRequest._associatedReadableByteStreamController=void 0;a._byobRequest._view=void 0;a._byobRequest=void 0}function La(a){r(a._closeRequested===!1);while(a._pendingPullIntos.length>0){if(a._queueTotalSize===0)return;var b=a._pendingPullIntos[0];Ha(a,b)===!0&&(Qa(a),Fa(a._controlledReadableStream,b))}}function Ma(a,c){var d=a._controlledReadableStream,e=1;c.constructor!==DataView&&(e=c.constructor.BYTES_PER_ELEMENT);var f=c.constructor;e={buffer:c.buffer,byteOffset:c.byteOffset,byteLength:c.byteLength,bytesFilled:0,elementSize:e,ctor:f,readerType:"byob"};if(a._pendingPullIntos.length>0){e.buffer=l(e.buffer);a._pendingPullIntos.push(e);return ma(d)}if(d._state==="closed"){f=new c.constructor(e.buffer,e.byteOffset,0);return b("MaybeNativePromise").resolve(h(f,!0))}if(a._queueTotalSize>0){if(Ha(a,e)===!0){c=Ga(e);Ja(a);return b("MaybeNativePromise").resolve(h(c,!1))}if(a._closeRequested===!0){f=new TypeError("Insufficient bytes to fill elements in the given buffer");U(a,f);return b("MaybeNativePromise").reject(f)}}e.buffer=l(e.buffer);a._pendingPullIntos.push(e);c=ma(d);S(a);return c}function Na(a,b){b.buffer=l(b.buffer);r(b.bytesFilled===0,"bytesFilled must be 0");b=a._controlledReadableStream;if(H(b)===!0)while(qa(b)>0){var c=Qa(a);Fa(b,c)}}function Oa(a,b,c){if(c.bytesFilled+b>c.byteLength)throw new RangeError("bytesWritten out of range");Ia(a,b,c);if(c.bytesFilled<c.elementSize)return;Qa(a);b=c.bytesFilled%c.elementSize;if(b>0){var d=c.byteOffset+c.bytesFilled;d=c.buffer.slice(d-b,d);T(a,d,0,d.byteLength)}c.buffer=l(c.buffer);c.bytesFilled-=b;Fa(a._controlledReadableStream,c);La(a)}function Pa(a,b){var c=a._pendingPullIntos[0],d=a._controlledReadableStream;if(d._state==="closed"){if(b!==0)throw new TypeError("bytesWritten must be 0 when calling respond() on a closed stream");Na(a,c)}else r(d._state==="readable"),Oa(a,b,c)}function Qa(a){var b=a._pendingPullIntos.shift();Ka(a);return b}function Ra(a){var b=a._controlledReadableStream;if(b._state!=="readable")return!1;if(a._closeRequested===!0)return!1;if(a._started===!1)return!1;if(I(b)===!0&&G(b)>0)return!0;if(H(b)===!0&&qa(b)>0)return!0;return Ua(a)>0?!0:!1}function Sa(a){var b=a._controlledReadableStream;r(a._closeRequested===!1);r(b._state==="readable");if(a._queueTotalSize>0){a._closeRequested=!0;return}if(a._pendingPullIntos.length>0){var c=a._pendingPullIntos[0];if(c.bytesFilled>0){c=new TypeError("Insufficient bytes to fill elements in the given buffer");U(a,c);throw c}}E(b)}function Ta(a,b){var c=a._controlledReadableStream;r(a._closeRequested===!1);r(c._state==="readable");var d=b.buffer,e=b.byteOffset;b=b.byteLength;d=l(d);if(I(c)===!0)if(G(c)===0)T(a,d,e,b);else{r(a._queue.length===0);var f=new Uint8Array(d,e,b);F(c,f,!1)}else H(c)===!0?(T(a,d,e,b),La(a)):(r(C(c)===!1,"stream must not be locked"),T(a,d,e,b))}function U(a,b){var c=a._controlledReadableStream;r(c._state==="readable");Ea(a);v(a);oa(c,b)}function Ua(a){var b=a._controlledReadableStream;b=b._state;if(b==="errored")return null;return b==="closed"?0:a._strategyHWM-a._queueTotalSize}function Va(a,b){b=Number(b);if(i(b)===!1)throw new RangeError("bytesWritten must be a finite");r(a._pendingPullIntos.length>0);Pa(a,b)}function Wa(a,b){r(a._pendingPullIntos.length>0);var c=a._pendingPullIntos[0];if(c.byteOffset+c.bytesFilled!==b.byteOffset)throw new RangeError("The region specified by view does not match byobRequest");if(c.byteLength!==b.byteLength)throw new RangeError("The buffer of view has different capacity than byobRequest");c.buffer=b.buffer;Pa(a,b.byteLength)}function V(a){return new TypeError("ReadableStream.prototype."+a+" can only be used on a ReadableStream")}function W(a){return new TypeError("Cannot "+a+" a stream using a released reader")}function X(a){return new TypeError("ReadableStreamDefaultReader.prototype."+a+" can only be used on a ReadableStreamDefaultReader")}function Xa(a){a._closedPromise=new(b("MaybeNativePromise"))(function(b,c){a._closedPromise_resolve=b,a._closedPromise_reject=c})}function Ya(a,c){a._closedPromise=b("MaybeNativePromise").reject(c),a._closedPromise_resolve=void 0,a._closedPromise_reject=void 0}function Za(a){a._closedPromise=b("MaybeNativePromise").resolve(void 0),a._closedPromise_resolve=void 0,a._closedPromise_reject=void 0}function $a(a,b){r(a._closedPromise_resolve!==void 0),r(a._closedPromise_reject!==void 0),a._closedPromise_reject(b),a._closedPromise_resolve=void 0,a._closedPromise_reject=void 0}function ab(a,c){r(a._closedPromise_resolve===void 0),r(a._closedPromise_reject===void 0),a._closedPromise=b("MaybeNativePromise").reject(c)}function bb(a){r(a._closedPromise_resolve!==void 0),r(a._closedPromise_reject!==void 0),a._closedPromise_resolve(void 0),a._closedPromise_resolve=void 0,a._closedPromise_reject=void 0}function Y(a){return new TypeError("ReadableStreamBYOBReader.prototype."+a+" can only be used on a ReadableStreamBYOBReader")}function Z(a){return new TypeError("ReadableStreamDefaultController.prototype."+a+" can only be used on a ReadableStreamDefaultController")}function cb(a){return new TypeError("ReadableStreamBYOBRequest.prototype."+a+" can only be used on a ReadableStreamBYOBRequest")}function $(a){return new TypeError("ReadableByteStreamController.prototype."+a+" can only be used on a ReadableByteStreamController")}function db(a){try{b("MaybeNativePromise").prototype.then.call(a,void 0,function(){})}catch(a){}}}),null);
__d("SkywalkerHelpers",[],(function(a,b,c,d,e,f){"use strict";function a(a){a=a.split("/").slice(0,-1);return a.some(function(a){return/\d/.test(a)})?null:a.join("_")}f.topicToUseCaseName=a}),66);
__d("SkywalkerManager",["Bootloader","Promise","SkywalkerHelpers","TransportSelectingClientSingleton","TransportSelectingClientUtils","asyncToGeneratorRuntime","nullthrows","promiseDone","requireDeferred"],(function(a,b,c,d,e,f,g){var h,i="request_stream";a="mqtt_skywalker";var j="dgw_request_stream";e=function(){function a(){}var e=a.prototype;e.subscribe=function(a,b,d){d===void 0&&(d={});var e=this.$3(a,b,d);c("promiseDone")(e);return{getTopic:function(){return a},getContext:function(){return d.context},isUnsubscribed:function(){return this.$4},unsubscribe:function(){this.$4=!0;return e.then(function(a){return a.unsubscribe()})},$4:!1}};e.once=function(a,b,c){c===void 0&&(c={});var d=this.subscribe(a,function(){d.isUnsubscribed()||(void d.unsubscribe(),b.apply(this,arguments))},c);return d};e.getSubscriptionType=function(){var a=b("asyncToGeneratorRuntime").asyncToGenerator(function*(a,b){return b!=null&&b.headers!=null?i:j});function c(b,c){return a.apply(this,arguments)}return c}();e.getSubscriptions=function(){var a=[],b=this.$1;b!=null&&(a=b.getSubscriptions().map(function(a){return{getTopic:function(){return a.getTopic()},getMessageListener:function(){return a.getMessageListener()},getCreationTime:function(){return a.getCreationTime()},isUnsubscribed:function(){return!b.isSubscribed(a)}}}));return a};e.$3=function(){var a=b("asyncToGeneratorRuntime").asyncToGenerator(function*(a,b,e){var f=(yield this.getSubscriptionType(a,e));if(f===i){var g=e.headers!=null?e.headers.method:null;return this.$5(c("nullthrows")(g),a,b,e)}else if(f===j){var h;g=e==null||(h=e.headers)==null?void 0:h.method;if(g==null){f=d("SkywalkerHelpers").topicToUseCaseName(a);f!=null?g="SKY:"+f:g="SKY"}return this.$5(c("nullthrows")(g),a,b,e)}else return this.$6(a,b,e)});function e(b,c,d){return a.apply(this,arguments)}return e}();e.$6=function(){var a=b("asyncToGeneratorRuntime").asyncToGenerator(function*(a,b,c){var d=(yield this.$7());return d.subscribe(a,b,c)});function c(b,c,d){return a.apply(this,arguments)}return c}();e.$5=function(){var a=b("asyncToGeneratorRuntime").asyncToGenerator(function*(a,d,e,f){var g=(yield this.$8());g=g.patchContext(f.context);a=babelHelpers["extends"]({},f.headers||{},{method:a,topic:d});var h={onData:function(a){a=JSON.parse(a);var b=d!=null?d:a.topic;e({topic:b,payload:a.payload})},onTermination:function(a){f.onTermination&&f.onTermination(a)},onLog:function(a){return void 0},onFlowStatus:function(a){return void 0}},i=(yield c("TransportSelectingClientSingleton").requestStream(a,JSON.stringify(g),h,f.instrumentationData));f.onSubscribe&&f.onSubscribe({data:{},error:null});return{unsubscribe:function(){var a=b("asyncToGeneratorRuntime").asyncToGenerator(function*(){f.onUnsubscribeEager&&f.onUnsubscribeEager(),i.cancel(),f.onUnsubscribe&&f.onUnsubscribe({data:{},error:null})});function c(){return a.apply(this,arguments)}return c}()}});function d(b,c,d,e){return a.apply(this,arguments)}return d}();e.$7=function(){var a=b("asyncToGeneratorRuntime").asyncToGenerator(function*(){if(this.$1!=null)return this.$1;var a=new(h||(h=b("Promise")))(function(a){c("Bootloader").loadModules(["MqttSkywalkerManager"],a,"SkywalkerManager")});a=(yield a);this.$1=a;return a});function d(){return a.apply(this,arguments)}return d}();e.$8=function(){var a=b("asyncToGeneratorRuntime").asyncToGenerator(function*(){if(this.$2!=null)return this.$2;var a=new(h||(h=b("Promise")))(function(a){c("requireDeferred")("SkywalkerUtils").__setRef("SkywalkerManager").onReady(function(b){a(b)})});a=(yield a);this.$2=a;return a});function d(){return a.apply(this,arguments)}return d}();return a}();f=new e();g["default"]=f}),98);
__d("SkywalkerUtils",["CurrentLocale","RTISubscriptionManagerConfig"],(function(a,b,c,d,e,f){a={patchContext:function(a){a=a||{};a.locale=b("CurrentLocale").get();if(b("RTISubscriptionManagerConfig").assimilator){var c=b("RTISubscriptionManagerConfig").assimilator;c.tierType!=null&&(a.tierType=c.tierType);c.sandboxIP!=null&&c.sandboxPort!=null&&c.sandboxHostname!=null&&(a.sandboxIP=c.sandboxIP,a.sandboxPort=c.sandboxPort,a.sandboxHostname=c.sandboxHostname)}return a}};e.exports=a}),null);